package message

import (
	"github.com/siddontang/go-mysql/mysql"
	"github.com/siddontang/go-mysql/replication"
)

type LoadMessage struct {
	TableName string 			`json:"table"`
	OpType string 				`json:"type"`
	LogPositionName string  	`json:"pos_name"`
	LogPosition uint32  		`json:"pos"`
	TableColumnNames []string	`json:"col_names"`
	TableColumnTypes []string	`json:"col_types"`
	Rows [][]interface{}		`json:"rows"`
}

type ProcessMessage struct {
	Operation string
	SchemeName string
	TableName string
	TableColumnNames []string
	TableColumnTypes []string
	Rows [][]interface{}
	Event *replication.RowsEvent
	Position mysql.Position
}
